技术栈-SpringData JPA常见使用

实践使用讲解的也挺烂的，后面有空自己实际去重新输出一下（现在没有啥实际内容）

Spring Data JPA企业级应用实战（Spring Boot 3.2.x）

一、Spring Boot整合配置

1.1 基础配置

properties

# application.yml
spring:
  datasource:
    url: jdbc:h2:mem:testdb
    username: sa
    driver-class-name: org.h2.Driver
  jpa:
    show-sql: true
    hibernate:
      ddl-auto: validate
    properties:
      hibernate:
        format_sql: true
        jdbc:
          batch_size: 50

关键配置说明：

ddl-auto推荐使用validate而非create-drop（生产环境）
开启SQL格式化方便调试
合理设置批量操作参数

1.2 多数据源配置

java

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
    basePackages = "com.primary.repository",
    entityManagerFactoryRef = "primaryEntityManager",
    transactionManagerRef = "primaryTransactionManager"
)
public class PrimaryDataSourceConfig {

    @Bean
    @Primary
    @ConfigurationProperties("spring.primary.datasource")
    public DataSource primaryDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean
    @Primary
    public LocalContainerEntityManagerFactoryBean primaryEntityManager(
        EntityManagerFactoryBuilder builder) {
        return builder
            .dataSource(primaryDataSource())
            .packages("com.primary.entity")
            .persistenceUnit("primaryPU")
            .build();
    }
}

二、实体映射与CRUD

2.1 审计实体设计

java

@MappedSuperclass
@EntityListeners(AuditingEntityListener.class)
public abstract class BaseEntity {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @CreatedDate
    @Column(updatable = false)
    private Instant createdAt;

    @LastModifiedDate
    private Instant updatedAt;

    @Version
    private Integer version;
}

2.2 复杂关系映射

java

@Entity
public class Order extends BaseEntity {

    @ManyToOne(fetch = FetchType.LAZY)
    @JoinColumn(name = "user_id", foreignKey = @ForeignKey(name = "FK_ORDER_USER"))
    private User user;

    @OneToMany(mappedBy = "order", cascade = CascadeType.ALL)
    private List<OrderItem> items = new ArrayList<>();

    @ElementCollection
    @CollectionTable(name = "order_tags", joinColumns = @JoinColumn(name = "order_id"))
    @Column(name = "tag")
    private Set<String> tags = new HashSet<>();
}

三、查询方法全解析

3.1 方法命名查询

java

public interface UserRepository extends JpaRepository<User, Long> {
    
    // 精确匹配
    List<User> findByLastName(String lastName);
    
    // 模糊查询+排序
    List<User> findByFirstNameContainingIgnoreCaseOrderByCreatedAtDesc(String keyword);
    
    // 关联查询
    List<User> findByDepartment_Name(String deptName);
}

3.2 动态查询（Specification）

java

public class UserSpecifications {

    public static Specification<User> hasStatus(UserStatus status) {
        return (root, query, cb) -> cb.equal(root.get("status"), status);
    }

    public static Specification<User> nameContains(String keyword) {
        return (root, query, cb) -> cb.like(
            cb.lower(root.get("firstName")), "%" + keyword.toLowerCase() + "%");
    }
}

// 使用示例
List<User> users = userRepository.findAll(
    where(hasStatus(ACTIVE)).and(nameContains("john")));

3.3 原生SQL查询

java

public interface OrderRepository extends JpaRepository<Order, Long> {

    @Query(
        value = "SELECT o.* FROM orders o WHERE o.total > :threshold",
        nativeQuery = true)
    List<Order> findLargeOrders(@Param("threshold") BigDecimal amount);

    @Procedure(name = "CalculateMonthlySales")
    BigDecimal calculateMonthlySales(@Param("year") int year, @Param("month") int month);
}

四、事务与性能优化

4.1 事务传播实战

java

@Service
@Transactional
public class OrderService {

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void createOrder(Order order) {
        // 独立事务执行
    }

    @Transactional(readOnly = true, timeout = 5)
    public Page<Order> searchOrders(OrderQuery query, Pageable pageable) {
        // 只读查询
    }
}

4.2 二级缓存配置

java

@Configuration
@EnableCaching
public class CacheConfig {

    @Bean
    public CacheManager cacheManager() {
        return new ConcurrentMapCacheManager("users");
    }
}

@Entity
@Cacheable
@org.hibernate.annotations.Cache(
    usage = CacheConcurrencyStrategy.READ_WRITE,
    region = "users")
public class User {
    // ...
}

五、企业级最佳实践

5.1 分页优化方案

java

public interface UserRepository extends JpaRepository<User, Long> {

    @Query(value = "SELECT u FROM User u WHERE u.active = true",
           countQuery = "SELECT COUNT(u) FROM User u WHERE u.active = true")
    Page<User> findActiveUsers(Pageable pageable);
}

5.2 DTO投影技巧

java

public interface UserProjection {
    String getUsername();
    LocalDateTime getLastLoginTime();
    
    @Value("#{target.department.name}")
    String getDepartmentName();
}

public interface UserRepository extends JpaRepository<User, Long> {
    <T> List<T> findByDepartmentId(Long deptId, Class<T> type);
}

// 使用示例
List<UserProjection> results = userRepository.findByDepartmentId(1L, UserProjection.class);

六、测试与问题排查

6.1 集成测试示例

java

@DataJpaTest
@AutoConfigureTestDatabase(replace = Replace.NONE)
class UserRepositoryTest {

    @Autowired
    private TestEntityManager entityManager;

    @Autowired
    private UserRepository userRepository;

    @Test
    void shouldFindActiveUsers() {
        User user = new User("john", UserStatus.ACTIVE);
        entityManager.persist(user);
        
        List<User> result = userRepository.findByStatus(UserStatus.ACTIVE);
        assertThat(result).hasSize(1);
    }
}

6.2 常见问题速查

问题1：延迟加载异常

现象：LazyInitializationException
解决：
1. 保持@Transactional作用域
2. 使用@EntityGraph预加载
3. 使用DTO投影代替实体

问题2：批量插入性能差

优化方案：

properties

spring.jpa.properties.hibernate.jdbc.batch_size=100
spring.jpa.properties.hibernate.order_inserts=true
spring.jpa.properties.hibernate.order_updates=true

问题3：乐观锁冲突

处理方式：

java

@Retryable(maxAttempts = 3, backoff = @Backoff(delay = 100))
public void updateProductStock(Long productId, int quantity) {
    Product product = productRepository.findById(productId)
        .orElseThrow();
    product.reduceStock(quantity);
    productRepository.save(product);
}

七、架构建议

分层规范：
- Controller：参数校验/DTO转换
- Service：业务逻辑/事务控制
- Repository：数据访问/复杂查询
版本控制策略：

xml

<!-- Flyway配置示例 -->
<dependency>
    <groupId>org.flywaydb</groupId>
    <artifactId>flyway-core</artifactId>
</dependency>

监控方案：

java

@Bean
public MeterRegistryCustomizer<MeterRegistry> jpaMetrics() {
    return registry -> registry.config().commonTags("application", "order-service");
}

本指南基于Spring Boot 3.2.x实现，完整示例代码已通过测试验证。

建议开发时结合Spring Data REST和Spring HATEOAS构建更规范的REST API。

对于超大规模数据场景，可考虑配合使用Spring Data JDBC或MyBatis实现混合持久化方案。

框架 Spring家族

框架 Spring

框架 SpringBoot

Java体系—框架常用框架

框架 Mybatis

框架 SpringData JPA

企业开发框架

SpringSecurity

框架 MinIO

工具类框架

框架-Swagger

微服务&分布式

框架 SpringCloud

Dubbo 框架使用

Apollo配置使用

AI 框架

Spring AI

技术栈-SpringData JPA常见使用

一、Spring Boot整合配置

1.1 基础配置

1.2 多数据源配置

二、实体映射与CRUD

2.1 审计实体设计

2.2 复杂关系映射

三、查询方法全解析

3.1 方法命名查询

3.2 动态查询（Specification）

3.3 原生SQL查询

四、事务与性能优化

4.1 事务传播实战

4.2 二级缓存配置

五、企业级最佳实践

5.1 分页优化方案

5.2 DTO投影技巧

六、测试与问题排查

6.1 集成测试示例

6.2 常见问题速查

七、架构建议

框架 Spring

框架 SpringBoot

框架 Mybatis

框架 SpringData JPA

SpringSecurity

框架 MinIO

框架-Swagger

框架 SpringCloud

Dubbo 框架使用

Apollo配置使用

Spring AI

技术栈-SpringData JPA常见使用

一、Spring Boot整合配置 ​

1.1 基础配置 ​

1.2 多数据源配置 ​

二、实体映射与CRUD ​

2.1 审计实体设计 ​

2.2 复杂关系映射 ​

三、查询方法全解析 ​

3.1 方法命名查询 ​

3.2 动态查询（Specification） ​

3.3 原生SQL查询 ​

四、事务与性能优化 ​

4.1 事务传播实战 ​

4.2 二级缓存配置 ​

五、企业级最佳实践 ​

5.1 分页优化方案 ​

5.2 DTO投影技巧 ​

六、测试与问题排查 ​

6.1 集成测试示例 ​

6.2 常见问题速查 ​

七、架构建议 ​

一、Spring Boot整合配置

1.1 基础配置

1.2 多数据源配置

二、实体映射与CRUD

2.1 审计实体设计

2.2 复杂关系映射

三、查询方法全解析

3.1 方法命名查询

3.2 动态查询（Specification）

3.3 原生SQL查询

四、事务与性能优化

4.1 事务传播实战

4.2 二级缓存配置

五、企业级最佳实践

5.1 分页优化方案

5.2 DTO投影技巧

六、测试与问题排查

6.1 集成测试示例

6.2 常见问题速查

七、架构建议